package com.ray.dfj;

import com.lmax.disruptor.EventHandler;

public class HandlerTask<T> extends SingleTask<T>{
	
	private EventHandler<T> handler;

	public void onEvent(T event, long sequence, boolean endOfBatch) throws Exception {
		handler.onEvent(event, sequence, endOfBatch);
	}

	public EventHandler<T> getHandler() {
		return handler;
	}

	public void setHandler(EventHandler<T> handler) {
		this.handler = handler;
	}
	

}
